google.golang.org/grpc.Server.opts (field)
64 uses
google.golang.org/grpc (current package)
server.go#L71: return srv.opts.creds
server.go#L126: opts serverOptions
server.go#L586: s.serverWorkerChannels = make([]chan *serverWorkerData, s.opts.numServerWorkers)
server.go#L587: for i := uint32(0); i < s.opts.numServerWorkers; i++ {
server.go#L594: for i := uint32(0); i < s.opts.numServerWorkers; i++ {
server.go#L611: opts: opts,
server.go#L626: if s.opts.numServerWorkers > 0 {
server.go#L878: rawConn.SetDeadline(time.Now().Add(s.opts.connectionTimeout))
server.go#L909: MaxStreams: s.opts.maxConcurrentStreams,
server.go#L910: ConnectionTimeout: s.opts.connectionTimeout,
server.go#L911: Credentials: s.opts.creds,
server.go#L912: InTapHandle: s.opts.inTapHandle,
server.go#L913: StatsHandlers: s.opts.statsHandlers,
server.go#L914: KeepaliveParams: s.opts.keepaliveParams,
server.go#L915: KeepalivePolicy: s.opts.keepalivePolicy,
server.go#L916: InitialWindowSize: s.opts.initialWindowSize,
server.go#L917: InitialConnWindowSize: s.opts.initialConnWindowSize,
server.go#L918: WriteBufferSize: s.opts.writeBufferSize,
server.go#L919: ReadBufferSize: s.opts.readBufferSize,
server.go#L921: MaxHeaderListSize: s.opts.maxHeaderListSize,
server.go#L922: HeaderTableSize: s.opts.headerTableSize,
server.go#L951: if s.opts.numServerWorkers > 0 {
server.go#L954: case s.serverWorkerChannels[atomic.AddUint32(&roundRobinCounter, 1)%s.opts.numServerWorkers] <- data:
server.go#L1009: st, err := transport.NewServerHandlerTransport(w, r, s.opts.statsHandlers)
server.go#L1119: if len(payload) > s.opts.maxSendMessageSize {
server.go#L1120: return status.Errorf(codes.ResourceExhausted, "grpc: trying to send message larger than max (%d vs. %d)", len(payload), s.opts.maxSendMessageSize)
server.go#L1124: for _, sh := range s.opts.statsHandlers {
server.go#L1135: interceptors := s.opts.chainUnaryInts
server.go#L1136: if s.opts.unaryInt != nil {
server.go#L1137: interceptors = append([]UnaryServerInterceptor{s.opts.unaryInt}, s.opts.chainUnaryInts...)
server.go#L1149: s.opts.unaryInt = chainedInt
server.go#L1168: shs := s.opts.statsHandlers
server.go#L1229: if s.opts.binaryLogger != nil {
server.go#L1230: if ml := s.opts.binaryLogger.GetMethodLogger(stream.Method()); ml != nil {
server.go#L1269: if rc := stream.RecvCompress(); s.opts.dc != nil && s.opts.dc.Type() == rc {
server.go#L1270: dc = s.opts.dc
server.go#L1284: if s.opts.cp != nil {
server.go#L1285: cp = s.opts.cp
server.go#L1299: d, err := recvAndDecompress(&parser{r: stream}, stream, dc, s.opts.maxReceiveMessageSize, payInfo, decomp)
server.go#L1336: reply, appErr := md.Handler(info.serviceImpl, ctx, df, s.opts.unaryInt)
server.go#L1450: interceptors := s.opts.chainStreamInts
server.go#L1451: if s.opts.streamInt != nil {
server.go#L1452: interceptors = append([]StreamServerInterceptor{s.opts.streamInt}, s.opts.chainStreamInts...)
server.go#L1464: s.opts.streamInt = chainedInt
server.go#L1486: shs := s.opts.statsHandlers
server.go#L1506: maxReceiveMessageSize: s.opts.maxReceiveMessageSize,
server.go#L1507: maxSendMessageSize: s.opts.maxSendMessageSize,
server.go#L1552: if s.opts.binaryLogger != nil {
server.go#L1553: if ml := s.opts.binaryLogger.GetMethodLogger(stream.Method()); ml != nil {
server.go#L1583: if rc := stream.RecvCompress(); s.opts.dc != nil && s.opts.dc.Type() == rc {
server.go#L1584: ss.dc = s.opts.dc
server.go#L1598: if s.opts.cp != nil {
server.go#L1599: ss.cp = s.opts.cp
server.go#L1600: stream.SetSendCompress(s.opts.cp.Type())
server.go#L1619: if s.opts.streamInt == nil {
server.go#L1627: appErr = s.opts.streamInt(server, ss, info, sd.Handler)
server.go#L1713: if unknownDesc := s.opts.unknownStreamDesc; unknownDesc != nil {
server.go#L1816: if s.opts.numServerWorkers > 0 {
server.go#L1875: if s.opts.codec != nil {
server.go#L1876: return s.opts.codec